package com.lion.queuerunner.test;

import com.lion.queue.runner.QueueRunner;

/**
 * TaskModel为输入 <br />
 * String 为返回值
 * 
 * @author liyongyao
 *
 */
public class RunnerDemo extends QueueRunner<TaskModel, String> {
	private static String QUEUENAME = "DemoQueue";

	public RunnerDemo() {
		super(QUEUENAME);
	}

	@Override
	protected String execute(TaskModel task) {
		System.out.println();
		System.out.println("任务：" + task.getTaskName() + "正在执行");
		System.out.println("任务：" + task.getTaskName() + "执行完毕");
		return "OK";
	}

}
